<?php

namespace app\common\command;

use app\manage\model\admin\SysCrontab;
use buwang\service\CacheService;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\facade\Console;


/**
 * 定时任务-弃用
 * Class Crontab
 */
class Crontab extends Command
{
    protected function configure()
    {
        $this->setName('crontab')
            ->setDescription('定时任务');
    }

    protected function execute(Input $input, Output $output)
    {
        $lists = CacheService::get('sys_crontab_key_mp', null);
        if (!$lists) {
            $lists = SysCrontab::where('is_open', 1)->select()->toArray();
            if ($lists){
                CacheService::set('sys_crontab_key_mp', $lists);
            }
        }

        if (empty($lists)) {
            return false;
        }
        $time =  time();
        foreach ($lists as $item) {
            $data = $this->getTimerCycleTime($item['type'], $item['cycle'], $time, $item['update_time']);
            if ($data['cycle_time'] != $time) {
                // 未到时间，不执行
                continue;
            }
            // 开始执行
            self::start($item);
        }
    }

    public static function start($item)
    {
        // 开始执行
        $startTime = microtime(true);
        try {
            $params = explode(' ', $item['params']);
            if (is_array($params) && !empty($item['params'])) {
                Console::call($item['command'], $params);
            } else {
                Console::call($item['command']);
            }
        } catch (\Exception $e) {
            // 记录错误信息
            file_put_contents(root_path().'runtime/crontab.txt', date('Y-m-d H:i:s', time()) . '-' . 'Crontab定时任务执行异常，原因：'.$e->getMessage().$e->getFile().$e->getLine().PHP_EOL,FILE_APPEND);
        } finally {
            $endTime = microtime(true);
            // 本次执行时间
            $useTime = round(($endTime - $startTime), 2);
            // 最大执行时间
            //$maxTime = max($useTime, $item['max_time']);
            // 更新最后执行时间
            SysCrontab::where('id', $item['id'])->update([
                'last_execution_time' => time(),
                'time' => $useTime,
                //'max_time' => $maxTime
            ]);
        }
    }

    /**获取下次执行时间
     * @param $type
     * @param $cycle
     * @param $time
     * @param $start_time
     * @return array
     */
    public function getTimerCycleTime($type, $cycle, $time, $start_time = 0)
    {
        if (!$time) $time = time();
        switch ($type) {
            case 1: // N分钟
                $cycle_time = 60 * $cycle;
                $i = $time - $start_time;
                $more = $i % $cycle_time;
                if ($more == 0) {
                    $cycle_time = $time;
                } else {
                    $cycle_time = $time - $more + $cycle_time;
                }
                break;
            case 2: //N小时
                $arr = explode('/', $cycle);
                $todaystart = strtotime(date('Y-m-d H' . ':00:00', $time));
                $start_time = strtotime(date('Y-m-d H' . ':00:00', $start_time));
                $h = ($todaystart - $start_time) / 3600;
                $h = floor($h);
                $more = $h % $arr[0];
                if ($more == 0) {
                    $cycle_time = 60 * $arr[1];
                    $cycle_time = $todaystart + $cycle_time;
                    if ($cycle_time <= $time) {
                        $cycle_time = 60 * 60 * $arr[0] + 60 * $arr[1];
                    }
                } else {
                    $sh = $arr[0] - $more;
                    $cycle_time = 60 * 60 * $sh + 60 * $arr[1];
                }
                $cycle_time = $todaystart + $cycle_time;
                break;
            case 3: //每小时
                $cycle_time = strtotime(date('Y-m-d ' . 'H:' . $cycle . ':00', $time));
                break;
            case 4: //每天
                $arr = explode('/', $cycle);
                $cycle_time = strtotime(date('Y-m-d ' . $arr[0] . ':' . $arr[1] . ':00', $time));
                break;
            case 5: //N天
                $arr = explode('/', $cycle);
                $todaystart = strtotime(date('Y-m-d ' . '00:00:00', $time));
                $start_time = strtotime(date('Y-m-d ' . '00:00:00', $start_time));
                $d = ($todaystart - $start_time) / 86400;
                $d = floor($d);
                $more = $d % $arr[0];
                if ($more == 0) {
                    $cycle_time = 60 * 60 * $arr[1] + 60 * $arr[2];
                    $cycle_time = $todaystart + $cycle_time;
                    if ($cycle_time < $time) {
                        $cycle_time = 60 * 60 * 24 * $more + 60 * 60 * $arr[1] + 60 * $arr[2];
                    }
                } else {
                    $sd = $arr[0] - $more;
                    $cycle_time = 60 * 60 * 24 * $sd + 60 * 60 * $arr[1] + 60 * $arr[2];
                }
                $cycle_time = $todaystart + $cycle_time;
                break;
            case 6: //每星期
                $arr = explode('/', $cycle);
                $todaystart = strtotime(date('Y-m-d ' . '00:00:00', $time));
                $w = date("w");
                if ($w > $arr[0]) {
                    $d = 7 - $w + $arr[0];
                    $cycle_time = $todaystart + 60 * 60 * 24 * $d + 60 * 60 * $arr[1] + 60 * $arr[2];
                } else if ($w == $arr[0]) {
                    $to_time = 60 * 60 * $arr[1] + 60 * $arr[2];
                    $to_time = $todaystart + $to_time;
                    if ($time > $to_time) {
                        $d = 7 - $w + $arr[0];
                        $cycle_time = $todaystart + 60 * 60 * 24 * $d + 60 * 60 * $arr[1] + 60 * $arr[2];
                    } else {
                        $cycle_time = $to_time;
                    }
                } else {
                    $d = $arr[0] - $w;
                    $cycle_time = $todaystart + 60 * 60 * 24 * $d + 60 * 60 * $arr[1] + 60 * $arr[2];
                }
                break;
            case 7: //每月
                $arr = explode('/', $cycle);
                $current_d = date("d");
                $firstDate = date('Y-m-01', $time);
                $max_d = date('d', strtotime("$firstDate + 1 month -1 day"));
                $todaystart = strtotime(date('Y-m-d ' . '00:00:00', $time));
                if ($current_d > $arr[0]) {
                    $d = $max_d - $current_d + $arr[0];
                    $cycle_time = $todaystart + 60 * 60 * 24 * $d + 60 * 60 * $arr[1] + 60 * $arr[2];
                } elseif ($current_d == $arr[0]) {
                    $to_time = 60 * 60 * $arr[1] + 60 * $arr[2];
                    $to_time = $todaystart + $to_time;
                    if ($time > $to_time) {
                        $d = $max_d - $current_d + $arr[0];
                        $cycle_time = $todaystart + 60 * 60 * 24 * $d + 60 * 60 * $arr[1] + 60 * $arr[2];
                    } else {
                        $cycle_time = $to_time;
                    }
                } else {
                    $d = $arr[0] - $current_d;
                    $cycle_time = $todaystart + 60 * 60 * 24 * $d + 60 * 60 * $arr[1] + 60 * $arr[2];
                }
                break;
            case 8: //每年
                $arr = explode('/', $cycle);
                $cycle_time = strtotime(date('Y-' . $arr[0] . '-' . $arr[1] . ' ' . $arr[2] . ':' . $arr[3] . ':00', $time));
                break;
            default:
                $cycle_time = 0;
                break;
        }
        return ['cycle_time' => $cycle_time];
    }

}